package com.bfxy.rabbit.api;

import com.bfxy.rabbit.api.exception.MessageRuntimeException;

import java.util.List;

/**
 * @author caryguan
 * @version V1.0
 * @Package com.bfxy.rabbit.api
 * @date 2020/9/30 18:24
 */
public interface MessageProducer {

    /**
     * 消息的发送附带sendcallback回调执行响应的业务逻辑处理
     * @param message
     * @param sendCallBack
     * @throws MessageRuntimeException
     */
    public void send(Message message,SendCallBack sendCallBack) throws MessageRuntimeException;

    public void send(Message message) throws MessageRuntimeException;

    public void send(List<Message> messages) throws MessageRuntimeException;

}